// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV
})

const db = cloud.database()

// 云函数入口函数
exports.main = async (event, context) => {
  console.log('initDatabase 云函数被调用');
  
  try {
    // 检查并创建 villagerVotes 集合
    try {
      await db.createCollection('villagerVotes')
      console.log('创建 villagerVotes 集合成功');
    } catch (err) {
      console.log('villagerVotes 集合已存在或创建失败:', err.message);
    }
    
    // 检查并创建 userVotes 集合
    try {
      await db.createCollection('userVotes')
      console.log('创建 userVotes 集合成功');
    } catch (err) {
      console.log('userVotes 集合已存在或创建失败:', err.message);
    }
    
    return {
      success: true,
      message: '数据库初始化完成'
    }
  } catch (error) {
    console.error('数据库初始化错误:', error);
    return {
      success: false,
      message: '数据库初始化失败',
      error: error.message || error
    }
  }
} 